package com.hyf.kafka.demo;

public class KafKaConsumerProducerDemo {

    public static void main(String[] args){

        KafKaProducer producerThread=new KafKaProducer(KafKaProperties.topic);
        producerThread.start();
        KafKaConsumer consumerThread=new KafKaConsumer(KafKaProperties.topic);
        consumerThread.start();
    }
}
